package com.etl.component.file.center;

import com.component.api.model.dto.FileCenterConfigDTO;

import java.io.InputStream;

/**
 * 描述：
 * 文件中心
 * @author xianggj
 * @Date 2021/12/1 11:28
 **/
public interface FileCenter {

    /**
     * 文件中心类型
     */
    String MINIO = "minio";
    String HDFS = "hdfs";

    /**
     * 缓存路径
     */
    String CHACE_PATH = "/temp/csvread";

    /**
     * 获取文件流
     * @return
     */
    InputStream getFileStream(FileCenterConfigDTO confg, String path) throws Exception;
}
